package com.chen.service;

import com.chen.bean.vo.FlowableResultVo;
import com.chen.bean.vo.MessageRequest;
import com.chen.exception.BusinessException;
import reactor.core.publisher.Flux;

public interface ChatService {

    Flux<String> chat(MessageRequest request, Integer userId) throws BusinessException;

    void syncMessage(String messageKey);

    String generatorDialogNumber(Integer userId);
}
